<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "https://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" lang="zh">
<head>
<meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/>
<meta http-equiv="X-UA-Compatible" content="IE=11"/>
<meta name="generator" content="Doxygen 1.9.8"/>
<meta name="viewport" content="width=device-width, initial-scale=1"/>
<title>线程池: lib/src/threads_pool.c 源文件</title>
<link href="tabs.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="jquery.js"></script>
<script type="text/javascript" src="dynsections.js"></script>
<link href="search/search.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="search/searchdata.js"></script>
<script type="text/javascript" src="search/search.js"></script>
<link href="doxygen.css" rel="stylesheet" type="text/css" />
</head>
<body>
<div id="top"><!-- do not remove this div, it is closed by doxygen! -->
<div id="titlearea">
<table cellspacing="0" cellpadding="0">
 <tbody>
 <tr id="projectrow">
  <td id="projectalign">
   <div id="projectname">线程池<span id="projectnumber">&#160;1.0.0</span>
   </div>
   <div id="projectbrief">多线程并发工具</div>
  </td>
 </tr>
 </tbody>
</table>
</div>
<!-- end header part -->
<!-- 制作者 Doxygen 1.9.8 -->
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&amp;dn=expat.txt MIT */
var searchBox = new SearchBox("searchBox", "search/",'.html');
/* @license-end */
</script>
<script type="text/javascript" src="menudata.js"></script>
<script type="text/javascript" src="menu.js"></script>
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&amp;dn=expat.txt MIT */
$(function() {
  initMenu('',true,false,'search.php','搜索');
  $(document).ready(function() { init_search(); });
});
/* @license-end */
</script>
<div id="main-nav"></div>
<script type="text/javascript">
/* @license magnet:?xt=urn:btih:d3d9a9a6595521f9666a5e94cc830dab83b65699&amp;dn=expat.txt MIT */
$(document).ready(function() { init_codefold(0); });
/* @license-end */
</script>
<!-- window showing the filter options -->
<div id="MSearchSelectWindow"
     onmouseover="return searchBox.OnSearchSelectShow()"
     onmouseout="return searchBox.OnSearchSelectHide()"
     onkeydown="return searchBox.OnSearchSelectKey(event)">
</div>

<!-- iframe showing the search results (closed by default) -->
<div id="MSearchResultsWindow">
<div id="MSearchResults">
<div class="SRPage">
<div id="SRIndex">
<div id="SRResults"></div>
<div class="SRStatus" id="Loading">载入中...</div>
<div class="SRStatus" id="Searching">搜索中...</div>
<div class="SRStatus" id="NoMatches">未找到</div>
</div>
</div>
</div>
</div>

<div id="nav-path" class="navpath">
  <ul>
<li class="navelem"><a class="el" href="dir_97aefd0d527b934f1d99a682da8fe6a9.html">lib</a></li><li class="navelem"><a class="el" href="dir_a065c5f60305fee3569f887679366939.html">src</a></li>  </ul>
</div>
</div><!-- top -->
<div class="header">
  <div class="headertitle"><div class="title">threads_pool.c</div></div>
</div><!--header-->
<div class="contents">
<a href="threads__pool_8c.html">浏览该文件的文档.</a><div class="fragment"><div class="line"><a id="l00001" name="l00001"></a><span class="lineno">    1</span> </div>
<div class="line"><a id="l00011" name="l00011"></a><span class="lineno">   11</span><span class="preprocessor">#ifndef __THREADS_POOL_C__</span></div>
<div class="line"><a id="l00012" name="l00012"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a697d5b2708d569fe0575a3b25a809dc1">   12</a></span><span class="preprocessor">#define __THREADS_POOL_C__</span></div>
<div class="line"><a id="l00013" name="l00013"></a><span class="lineno">   13</span> </div>
<div class="line"><a id="l00014" name="l00014"></a><span class="lineno">   14</span><span class="preprocessor">#include &lt;<a class="code" href="threads__pool_8h.html">threads_pool.h</a>&gt;</span></div>
<div class="line"><a id="l00015" name="l00015"></a><span class="lineno">   15</span> </div>
<div class="line"><a id="l00016" name="l00016"></a><span class="lineno">   16</span> </div>
<div class="foldopen" id="foldopen00025" data-start="{" data-end="}">
<div class="line"><a id="l00025" name="l00025"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">   25</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a> (</div>
<div class="line"><a id="l00026" name="l00026"></a><span class="lineno">   26</span>    <span class="keywordtype">void</span>* arg   </div>
<div class="line"><a id="l00027" name="l00027"></a><span class="lineno">   27</span>)</div>
<div class="line"><a id="l00028" name="l00028"></a><span class="lineno">   28</span>{</div>
<div class="line"><a id="l00029" name="l00029"></a><span class="lineno">   29</span>    <span class="comment">// 互斥锁地址</span></div>
<div class="line"><a id="l00030" name="l00030"></a><span class="lineno">   30</span>    pthread_mutex_t* mtxUnPt;</div>
<div class="line"><a id="l00031" name="l00031"></a><span class="lineno">   31</span> </div>
<div class="line"><a id="l00032" name="l00032"></a><span class="lineno">   32</span>    <span class="comment">// 初始化互斥锁地址</span></div>
<div class="line"><a id="l00033" name="l00033"></a><span class="lineno">   33</span>    mtxUnPt = (pthread_mutex_t*)arg;</div>
<div class="line"><a id="l00034" name="l00034"></a><span class="lineno">   34</span> </div>
<div class="line"><a id="l00035" name="l00035"></a><span class="lineno">   35</span>    <span class="comment">// 解锁</span></div>
<div class="line"><a id="l00036" name="l00036"></a><span class="lineno">   36</span>    pthread_mutex_unlock(mtxUnPt);    </div>
<div class="line"><a id="l00037" name="l00037"></a><span class="lineno">   37</span>}</div>
</div>
<div class="line"><a id="l00038" name="l00038"></a><span class="lineno">   38</span> </div>
<div class="foldopen" id="foldopen00050" data-start="{" data-end="}">
<div class="line"><a id="l00050" name="l00050"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a4ebf31958db9354ac6dcdb000e723303">   50</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> <a class="code hl_function" href="threads__pool_8c.html#a4ebf31958db9354ac6dcdb000e723303">getNewTaskMsg</a> (</div>
<div class="line"><a id="l00051" name="l00051"></a><span class="lineno">   51</span>    <span class="keywordtype">void</span>* (* handleFuncPt)(<span class="keywordtype">void</span>* arg),  </div>
<div class="line"><a id="l00052" name="l00052"></a><span class="lineno">   52</span>    <span class="keywordtype">void</span>* handleFuncArg                 </div>
<div class="line"><a id="l00053" name="l00053"></a><span class="lineno">   53</span>)</div>
<div class="line"><a id="l00054" name="l00054"></a><span class="lineno">   54</span>{</div>
<div class="line"><a id="l00055" name="l00055"></a><span class="lineno">   55</span>    <span class="comment">// 新任务信息地址</span></div>
<div class="line"><a id="l00056" name="l00056"></a><span class="lineno">   56</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> newTaskMsgStPt;</div>
<div class="line"><a id="l00057" name="l00057"></a><span class="lineno">   57</span> </div>
<div class="line"><a id="l00058" name="l00058"></a><span class="lineno">   58</span>    <span class="comment">// 分配新任务信息内存</span></div>
<div class="line"><a id="l00059" name="l00059"></a><span class="lineno">   59</span>    newTaskMsgStPt = malloc(<span class="keyword">sizeof</span>(<a class="code hl_struct" href="structtask_msg.html">TaskMsg_st</a>));</div>
<div class="line"><a id="l00060" name="l00060"></a><span class="lineno">   60</span> </div>
<div class="line"><a id="l00061" name="l00061"></a><span class="lineno">   61</span>    <span class="comment">// 初始化新任务信息</span></div>
<div class="line"><a id="l00062" name="l00062"></a><span class="lineno">   62</span>    newTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a320a82ee2a68ce91e1c149979d694665">handleFuncPt</a> = handleFuncPt;</div>
<div class="line"><a id="l00063" name="l00063"></a><span class="lineno">   63</span>    newTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a9efefa9e58ba07cae75d220d1b25c435">handleFuncArg</a> = handleFuncArg;</div>
<div class="line"><a id="l00064" name="l00064"></a><span class="lineno">   64</span>    newTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = newTaskMsgStPt;</div>
<div class="line"><a id="l00065" name="l00065"></a><span class="lineno">   65</span>    newTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = newTaskMsgStPt;</div>
<div class="line"><a id="l00066" name="l00066"></a><span class="lineno">   66</span> </div>
<div class="line"><a id="l00067" name="l00067"></a><span class="lineno">   67</span>    <span class="keywordflow">return</span> newTaskMsgStPt;</div>
<div class="line"><a id="l00068" name="l00068"></a><span class="lineno">   68</span>}</div>
</div>
<div class="line"><a id="l00069" name="l00069"></a><span class="lineno">   69</span> </div>
<div class="foldopen" id="foldopen00079" data-start="{" data-end="}">
<div class="line"><a id="l00079" name="l00079"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#ab8f5739158324ca3499012ae04bce8cd">   79</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#ab8f5739158324ca3499012ae04bce8cd">inqueueNewTaskMsg</a> (</div>
<div class="line"><a id="l00080" name="l00080"></a><span class="lineno">   80</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt,    </div>
<div class="line"><a id="l00081" name="l00081"></a><span class="lineno">   81</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> newTaskMsgStPt            </div>
<div class="line"><a id="l00082" name="l00082"></a><span class="lineno">   82</span>)</div>
<div class="line"><a id="l00083" name="l00083"></a><span class="lineno">   83</span>{</div>
<div class="line"><a id="l00084" name="l00084"></a><span class="lineno">   84</span>    <span class="comment">// 更新新任务信息</span></div>
<div class="line"><a id="l00085" name="l00085"></a><span class="lineno">   85</span>    newTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a>;</div>
<div class="line"><a id="l00086" name="l00086"></a><span class="lineno">   86</span>    newTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>;</div>
<div class="line"><a id="l00087" name="l00087"></a><span class="lineno">   87</span>    <span class="comment">// 更新线程池</span></div>
<div class="line"><a id="l00088" name="l00088"></a><span class="lineno">   88</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = newTaskMsgStPt;</div>
<div class="line"><a id="l00089" name="l00089"></a><span class="lineno">   89</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = newTaskMsgStPt;</div>
<div class="line"><a id="l00090" name="l00090"></a><span class="lineno">   90</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> ++;</div>
<div class="line"><a id="l00091" name="l00091"></a><span class="lineno">   91</span>}</div>
</div>
<div class="line"><a id="l00092" name="l00092"></a><span class="lineno">   92</span> </div>
<div class="foldopen" id="foldopen00103" data-start="{" data-end="}">
<div class="line"><a id="l00103" name="l00103"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#af90c938ee855b735b0c0b9f82f9e6d67">  103</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> <a class="code hl_function" href="threads__pool_8c.html#af90c938ee855b735b0c0b9f82f9e6d67">dequeueTaskMsg</a> (</div>
<div class="line"><a id="l00104" name="l00104"></a><span class="lineno">  104</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00105" name="l00105"></a><span class="lineno">  105</span>)</div>
<div class="line"><a id="l00106" name="l00106"></a><span class="lineno">  106</span>{</div>
<div class="line"><a id="l00107" name="l00107"></a><span class="lineno">  107</span>    <span class="comment">// 任务链队头地址</span></div>
<div class="line"><a id="l00108" name="l00108"></a><span class="lineno">  108</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> tasksHeadStPt;</div>
<div class="line"><a id="l00109" name="l00109"></a><span class="lineno">  109</span> </div>
<div class="line"><a id="l00110" name="l00110"></a><span class="lineno">  110</span>    <span class="comment">// 初始化任务链队头地址</span></div>
<div class="line"><a id="l00111" name="l00111"></a><span class="lineno">  111</span>    tasksHeadStPt = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a>;</div>
<div class="line"><a id="l00112" name="l00112"></a><span class="lineno">  112</span>    <span class="comment">// 更新线程池</span></div>
<div class="line"><a id="l00113" name="l00113"></a><span class="lineno">  113</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = tasksHeadStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a>;</div>
<div class="line"><a id="l00114" name="l00114"></a><span class="lineno">  114</span>    tasksHeadStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>;</div>
<div class="line"><a id="l00115" name="l00115"></a><span class="lineno">  115</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> --;</div>
<div class="line"><a id="l00116" name="l00116"></a><span class="lineno">  116</span>    <span class="comment">// 更新任务链队头</span></div>
<div class="line"><a id="l00117" name="l00117"></a><span class="lineno">  117</span>    tasksHeadStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = tasksHeadStPt;</div>
<div class="line"><a id="l00118" name="l00118"></a><span class="lineno">  118</span>    tasksHeadStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = tasksHeadStPt;</div>
<div class="line"><a id="l00119" name="l00119"></a><span class="lineno">  119</span> </div>
<div class="line"><a id="l00120" name="l00120"></a><span class="lineno">  120</span>    <span class="keywordflow">return</span> tasksHeadStPt;</div>
<div class="line"><a id="l00121" name="l00121"></a><span class="lineno">  121</span>}</div>
</div>
<div class="line"><a id="l00122" name="l00122"></a><span class="lineno">  122</span> </div>
<div class="foldopen" id="foldopen00134" data-start="{" data-end="}">
<div class="line"><a id="l00134" name="l00134"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a8a38ce3bf239e8daae72e3d7f7fc66a7">  134</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">int</span> <a class="code hl_function" href="threads__pool_8c.html#a8a38ce3bf239e8daae72e3d7f7fc66a7">removeDestTaskMsg</a> (</div>
<div class="line"><a id="l00135" name="l00135"></a><span class="lineno">  135</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt,    </div>
<div class="line"><a id="l00136" name="l00136"></a><span class="lineno">  136</span>    <span class="keywordtype">void</span>* (* destHandleFuncPt)(<span class="keywordtype">void</span>* arg)   </div>
<div class="line"><a id="l00137" name="l00137"></a><span class="lineno">  137</span>)</div>
<div class="line"><a id="l00138" name="l00138"></a><span class="lineno">  138</span>{</div>
<div class="line"><a id="l00139" name="l00139"></a><span class="lineno">  139</span>    <span class="comment">// 删除标志</span></div>
<div class="line"><a id="l00140" name="l00140"></a><span class="lineno">  140</span>    <span class="keywordtype">int</span> rmFlag;</div>
<div class="line"><a id="l00141" name="l00141"></a><span class="lineno">  141</span>    <span class="comment">// 目标任务信息地址</span></div>
<div class="line"><a id="l00142" name="l00142"></a><span class="lineno">  142</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> destTaskMsgStPt;</div>
<div class="line"><a id="l00143" name="l00143"></a><span class="lineno">  143</span> </div>
<div class="line"><a id="l00144" name="l00144"></a><span class="lineno">  144</span>    <span class="comment">// 初始化删除标志</span></div>
<div class="line"><a id="l00145" name="l00145"></a><span class="lineno">  145</span>    rmFlag = -1;</div>
<div class="line"><a id="l00146" name="l00146"></a><span class="lineno">  146</span>    <span class="comment">// 初始化目标任务信息地址</span></div>
<div class="line"><a id="l00147" name="l00147"></a><span class="lineno">  147</span>    <span class="keywordflow">for</span> (</div>
<div class="line"><a id="l00148" name="l00148"></a><span class="lineno">  148</span>        destTaskMsgStPt = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a>;</div>
<div class="line"><a id="l00149" name="l00149"></a><span class="lineno">  149</span>        destTaskMsgStPt != trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>;</div>
<div class="line"><a id="l00150" name="l00150"></a><span class="lineno">  150</span>        destTaskMsgStPt = destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a></div>
<div class="line"><a id="l00151" name="l00151"></a><span class="lineno">  151</span>    )</div>
<div class="line"><a id="l00152" name="l00152"></a><span class="lineno">  152</span>    {</div>
<div class="line"><a id="l00153" name="l00153"></a><span class="lineno">  153</span>        <span class="keywordflow">if</span> (destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a320a82ee2a68ce91e1c149979d694665">handleFuncPt</a> == destHandleFuncPt)</div>
<div class="line"><a id="l00154" name="l00154"></a><span class="lineno">  154</span>        {</div>
<div class="line"><a id="l00155" name="l00155"></a><span class="lineno">  155</span>            <span class="comment">// 更新线程池</span></div>
<div class="line"><a id="l00156" name="l00156"></a><span class="lineno">  156</span>            destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a>;</div>
<div class="line"><a id="l00157" name="l00157"></a><span class="lineno">  157</span>            destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a>-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a>;</div>
<div class="line"><a id="l00158" name="l00158"></a><span class="lineno">  158</span>            trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> --;</div>
<div class="line"><a id="l00159" name="l00159"></a><span class="lineno">  159</span>            <span class="comment">// 更新目标任务信息</span></div>
<div class="line"><a id="l00160" name="l00160"></a><span class="lineno">  160</span>            destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a320a82ee2a68ce91e1c149979d694665">handleFuncPt</a> = NULL;</div>
<div class="line"><a id="l00161" name="l00161"></a><span class="lineno">  161</span>            destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a9efefa9e58ba07cae75d220d1b25c435">handleFuncArg</a> = NULL;</div>
<div class="line"><a id="l00162" name="l00162"></a><span class="lineno">  162</span>            destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">prevTaskMsgStPt</a> = destTaskMsgStPt;</div>
<div class="line"><a id="l00163" name="l00163"></a><span class="lineno">  163</span>            destTaskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">nextTaskMsgStPt</a> = destTaskMsgStPt;</div>
<div class="line"><a id="l00164" name="l00164"></a><span class="lineno">  164</span>            <span class="comment">// 释放目标任务信息内存</span></div>
<div class="line"><a id="l00165" name="l00165"></a><span class="lineno">  165</span>            free(destTaskMsgStPt);</div>
<div class="line"><a id="l00166" name="l00166"></a><span class="lineno">  166</span>            <span class="comment">// 更新删除标志</span></div>
<div class="line"><a id="l00167" name="l00167"></a><span class="lineno">  167</span>            rmFlag = 0;</div>
<div class="line"><a id="l00168" name="l00168"></a><span class="lineno">  168</span>            <span class="keywordflow">break</span>;</div>
<div class="line"><a id="l00169" name="l00169"></a><span class="lineno">  169</span>        }</div>
<div class="line"><a id="l00170" name="l00170"></a><span class="lineno">  170</span>    }</div>
<div class="line"><a id="l00171" name="l00171"></a><span class="lineno">  171</span> </div>
<div class="line"><a id="l00172" name="l00172"></a><span class="lineno">  172</span>    <span class="keywordflow">return</span> rmFlag;</div>
<div class="line"><a id="l00173" name="l00173"></a><span class="lineno">  173</span>}</div>
</div>
<div class="line"><a id="l00174" name="l00174"></a><span class="lineno">  174</span> </div>
<div class="foldopen" id="foldopen00185" data-start="{" data-end="}">
<div class="line"><a id="l00185" name="l00185"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a649af44a3d418d82c8be4cc9e28be41d">  185</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span>* <a class="code hl_function" href="threads__pool_8c.html#a649af44a3d418d82c8be4cc9e28be41d">threadRoutine</a> (</div>
<div class="line"><a id="l00186" name="l00186"></a><span class="lineno">  186</span>    <span class="keywordtype">void</span>* arg   </div>
<div class="line"><a id="l00187" name="l00187"></a><span class="lineno">  187</span>)</div>
<div class="line"><a id="l00188" name="l00188"></a><span class="lineno">  188</span>{</div>
<div class="line"><a id="l00189" name="l00189"></a><span class="lineno">  189</span>    <span class="comment">// 线程池信息地址</span></div>
<div class="line"><a id="l00190" name="l00190"></a><span class="lineno">  190</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt;</div>
<div class="line"><a id="l00191" name="l00191"></a><span class="lineno">  191</span> </div>
<div class="line"><a id="l00192" name="l00192"></a><span class="lineno">  192</span>    <span class="comment">// 初始化线程池信息地址</span></div>
<div class="line"><a id="l00193" name="l00193"></a><span class="lineno">  193</span>    trdsPolMsgStPt = (<a class="code hl_typedef" href="threads__pool_8h.html#a5a467b16d23990346745beeffa68a36f">ThreadsPoolMsg_st_pt</a>)arg;</div>
<div class="line"><a id="l00194" name="l00194"></a><span class="lineno">  194</span>    <span class="comment">// 任务信息地址</span></div>
<div class="line"><a id="l00195" name="l00195"></a><span class="lineno">  195</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> taskMsgStPt;</div>
<div class="line"><a id="l00196" name="l00196"></a><span class="lineno">  196</span> </div>
<div class="line"><a id="l00197" name="l00197"></a><span class="lineno">  197</span>    <span class="keywordflow">while</span> (1) </div>
<div class="line"><a id="l00198" name="l00198"></a><span class="lineno">  198</span>    {</div>
<div class="line"><a id="l00199" name="l00199"></a><span class="lineno">  199</span>        <span class="comment">/* +++++++++++++++++++ 压栈预清理函数并加锁 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00200" name="l00200"></a><span class="lineno">  200</span>        <a class="code hl_define" href="threads__pool_8h.html#ade228054bfa068c8720ccbdd9bd60f1f">READY_CLEAN_UP_AND_LOCK</a>(<a class="code hl_function" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a>, &amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00201" name="l00201"></a><span class="lineno">  201</span>        <span class="comment">/* ↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓ */</span></div>
<div class="line"><a id="l00202" name="l00202"></a><span class="lineno">  202</span>        <span class="comment">// 注意: </span></div>
<div class="line"><a id="l00203" name="l00203"></a><span class="lineno">  203</span>        <span class="comment">// 一定要为等待条件加一个用来判断线程池是否启动销毁的条件判断，</span></div>
<div class="line"><a id="l00204" name="l00204"></a><span class="lineno">  204</span>        <span class="comment">// 否则即使线程池启动销毁，也会因为无任务继续等待导致一直阻塞在接合的过程，无法退出</span></div>
<div class="line"><a id="l00205" name="l00205"></a><span class="lineno">  205</span>        <span class="keywordflow">while</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> == 0 &amp;&amp; trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0a0f5965804f3bc796600f6ecf66ba20">shutDown</a> == <span class="keyword">false</span>)</div>
<div class="line"><a id="l00206" name="l00206"></a><span class="lineno">  206</span>        {</div>
<div class="line"><a id="l00207" name="l00207"></a><span class="lineno">  207</span>            <span class="comment">// 无等待任务，且线程池未启动销毁，等待新任务</span></div>
<div class="line"><a id="l00208" name="l00208"></a><span class="lineno">  208</span>            pthread_cond_wait(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0fb5277da524002442dfdd04bd95a852">codUn</a>, &amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00209" name="l00209"></a><span class="lineno">  209</span>        }</div>
<div class="line"><a id="l00210" name="l00210"></a><span class="lineno">  210</span>        <span class="keywordflow">if</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0a0f5965804f3bc796600f6ecf66ba20">shutDown</a> == <span class="keyword">true</span> &amp;&amp; trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> == 0)</div>
<div class="line"><a id="l00211" name="l00211"></a><span class="lineno">  211</span>        {</div>
<div class="line"><a id="l00212" name="l00212"></a><span class="lineno">  212</span>            <span class="comment">// 线程池启动销毁且没有待处理任务，退出线程</span></div>
<div class="line"><a id="l00213" name="l00213"></a><span class="lineno">  213</span>            pthread_mutex_unlock(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00214" name="l00214"></a><span class="lineno">  214</span>            pthread_exit(NULL);</div>
<div class="line"><a id="l00215" name="l00215"></a><span class="lineno">  215</span>        }</div>
<div class="line"><a id="l00216" name="l00216"></a><span class="lineno">  216</span>        <span class="comment">// 出队任务信息</span></div>
<div class="line"><a id="l00217" name="l00217"></a><span class="lineno">  217</span>        taskMsgStPt = <a class="code hl_function" href="threads__pool_8c.html#af90c938ee855b735b0c0b9f82f9e6d67">dequeueTaskMsg</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00218" name="l00218"></a><span class="lineno">  218</span>        <span class="comment">/* ↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ */</span></div>
<div class="line"><a id="l00219" name="l00219"></a><span class="lineno">  219</span>        <a class="code hl_define" href="threads__pool_8h.html#aad77b3322f3824da508dfbd0d04aa1a3">UNLOCK_AND_CANCEL_CLEAN_UP</a>(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00220" name="l00220"></a><span class="lineno">  220</span>        <span class="comment">/* +++++++++++++++++++ 解锁并出栈预清理函数 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00221" name="l00221"></a><span class="lineno">  221</span>        <span class="comment">// 禁用线程取消功能</span></div>
<div class="line"><a id="l00222" name="l00222"></a><span class="lineno">  222</span>        pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);</div>
<div class="line"><a id="l00223" name="l00223"></a><span class="lineno">  223</span>        <span class="comment">// 执行任务</span></div>
<div class="line"><a id="l00224" name="l00224"></a><span class="lineno">  224</span>        taskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a320a82ee2a68ce91e1c149979d694665">handleFuncPt</a>(taskMsgStPt-&gt;<a class="code hl_variable" href="structtask_msg.html#a9efefa9e58ba07cae75d220d1b25c435">handleFuncArg</a>);</div>
<div class="line"><a id="l00225" name="l00225"></a><span class="lineno">  225</span>        <span class="comment">// 启用线程取消功能</span></div>
<div class="line"><a id="l00226" name="l00226"></a><span class="lineno">  226</span>        pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);</div>
<div class="line"><a id="l00227" name="l00227"></a><span class="lineno">  227</span>        <span class="comment">// 释放执行完毕的任务信息内存</span></div>
<div class="line"><a id="l00228" name="l00228"></a><span class="lineno">  228</span>        free(taskMsgStPt);</div>
<div class="line"><a id="l00229" name="l00229"></a><span class="lineno">  229</span>    }</div>
<div class="line"><a id="l00230" name="l00230"></a><span class="lineno">  230</span> </div>
<div class="line"><a id="l00231" name="l00231"></a><span class="lineno">  231</span>    <span class="comment">// 退出线程</span></div>
<div class="line"><a id="l00232" name="l00232"></a><span class="lineno">  232</span>    pthread_exit(NULL);</div>
<div class="line"><a id="l00233" name="l00233"></a><span class="lineno">  233</span>}</div>
</div>
<div class="line"><a id="l00234" name="l00234"></a><span class="lineno">  234</span> </div>
<div class="foldopen" id="foldopen00245" data-start="{" data-end="}">
<div class="line"><a id="l00245" name="l00245"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a6c30c7bb23d59ef4146a65f8fc66976f">  245</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st_pt</a> <a class="code hl_function" href="threads__pool_8c.html#a6c30c7bb23d59ef4146a65f8fc66976f">getNewThreadMsg</a> (</div>
<div class="line"><a id="l00246" name="l00246"></a><span class="lineno">  246</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00247" name="l00247"></a><span class="lineno">  247</span>)</div>
<div class="line"><a id="l00248" name="l00248"></a><span class="lineno">  248</span>{</div>
<div class="line"><a id="l00249" name="l00249"></a><span class="lineno">  249</span>    <span class="comment">// 新线程信息地址</span></div>
<div class="line"><a id="l00250" name="l00250"></a><span class="lineno">  250</span>    <a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st_pt</a> newTrdMsgStPt;</div>
<div class="line"><a id="l00251" name="l00251"></a><span class="lineno">  251</span> </div>
<div class="line"><a id="l00252" name="l00252"></a><span class="lineno">  252</span>    <span class="comment">// 分配新线程信息内存</span></div>
<div class="line"><a id="l00253" name="l00253"></a><span class="lineno">  253</span>    newTrdMsgStPt = malloc(<span class="keyword">sizeof</span>(<a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st</a>));</div>
<div class="line"><a id="l00254" name="l00254"></a><span class="lineno">  254</span> </div>
<div class="line"><a id="l00255" name="l00255"></a><span class="lineno">  255</span>    <span class="comment">// 初始化新线程信息</span></div>
<div class="line"><a id="l00256" name="l00256"></a><span class="lineno">  256</span>    <span class="keywordflow">if</span> (trdsPolMsgStPt != NULL)</div>
<div class="line"><a id="l00257" name="l00257"></a><span class="lineno">  257</span>    {</div>
<div class="line"><a id="l00258" name="l00258"></a><span class="lineno">  258</span>        <span class="comment">// 非创建入口</span></div>
<div class="line"><a id="l00259" name="l00259"></a><span class="lineno">  259</span>        pthread_create(&amp;newTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#ae68dfff2f96d2414dfbd3959a79e1b43">tid</a>, NULL, <a class="code hl_function" href="threads__pool_8c.html#a649af44a3d418d82c8be4cc9e28be41d">threadRoutine</a>, (<span class="keywordtype">void</span>*)trdsPolMsgStPt);</div>
<div class="line"><a id="l00260" name="l00260"></a><span class="lineno">  260</span>    }</div>
<div class="line"><a id="l00261" name="l00261"></a><span class="lineno">  261</span>    newTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a> = newTrdMsgStPt;</div>
<div class="line"><a id="l00262" name="l00262"></a><span class="lineno">  262</span>    newTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#affe4d46391e29e73eba06baa6897baac">nextTrdMsgStPt</a> = newTrdMsgStPt;</div>
<div class="line"><a id="l00263" name="l00263"></a><span class="lineno">  263</span> </div>
<div class="line"><a id="l00264" name="l00264"></a><span class="lineno">  264</span>    <span class="keywordflow">return</span> newTrdMsgStPt;</div>
<div class="line"><a id="l00265" name="l00265"></a><span class="lineno">  265</span>}</div>
</div>
<div class="line"><a id="l00266" name="l00266"></a><span class="lineno">  266</span> </div>
<div class="foldopen" id="foldopen00276" data-start="{" data-end="}">
<div class="line"><a id="l00276" name="l00276"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a230969f5746c1add90070d33c4ac7092">  276</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#a230969f5746c1add90070d33c4ac7092">insertNewThreadMsg</a> (</div>
<div class="line"><a id="l00277" name="l00277"></a><span class="lineno">  277</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt,    </div>
<div class="line"><a id="l00278" name="l00278"></a><span class="lineno">  278</span>    <a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st_pt</a> newTrdMsgStPt           </div>
<div class="line"><a id="l00279" name="l00279"></a><span class="lineno">  279</span>)</div>
<div class="line"><a id="l00280" name="l00280"></a><span class="lineno">  280</span>{</div>
<div class="line"><a id="l00281" name="l00281"></a><span class="lineno">  281</span>    <span class="comment">// 更新新线程信息</span></div>
<div class="line"><a id="l00282" name="l00282"></a><span class="lineno">  282</span>    newTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a> = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a>;</div>
<div class="line"><a id="l00283" name="l00283"></a><span class="lineno">  283</span>    newTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#affe4d46391e29e73eba06baa6897baac">nextTrdMsgStPt</a> = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>;</div>
<div class="line"><a id="l00284" name="l00284"></a><span class="lineno">  284</span>    <span class="comment">// 更新线程池</span></div>
<div class="line"><a id="l00285" name="l00285"></a><span class="lineno">  285</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a> = newTrdMsgStPt;</div>
<div class="line"><a id="l00286" name="l00286"></a><span class="lineno">  286</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#affe4d46391e29e73eba06baa6897baac">nextTrdMsgStPt</a> = newTrdMsgStPt;</div>
<div class="line"><a id="l00287" name="l00287"></a><span class="lineno">  287</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">activeThreadsCot</a> ++;</div>
<div class="line"><a id="l00288" name="l00288"></a><span class="lineno">  288</span>}</div>
</div>
<div class="line"><a id="l00289" name="l00289"></a><span class="lineno">  289</span> </div>
<div class="foldopen" id="foldopen00298" data-start="{" data-end="}">
<div class="line"><a id="l00298" name="l00298"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a14fc4d285be60008c10b4c2520d770f4">  298</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#a14fc4d285be60008c10b4c2520d770f4">removeThreadMsg</a> (</div>
<div class="line"><a id="l00299" name="l00299"></a><span class="lineno">  299</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00300" name="l00300"></a><span class="lineno">  300</span>)</div>
<div class="line"><a id="l00301" name="l00301"></a><span class="lineno">  301</span>{</div>
<div class="line"><a id="l00302" name="l00302"></a><span class="lineno">  302</span>    <span class="comment">// 表尾线程信息地址</span></div>
<div class="line"><a id="l00303" name="l00303"></a><span class="lineno">  303</span>    <a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st_pt</a> tailTrdMsgStPt;</div>
<div class="line"><a id="l00304" name="l00304"></a><span class="lineno">  304</span> </div>
<div class="line"><a id="l00305" name="l00305"></a><span class="lineno">  305</span>    <span class="comment">// 初始化表尾线程信息地址</span></div>
<div class="line"><a id="l00306" name="l00306"></a><span class="lineno">  306</span>    tailTrdMsgStPt = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a>;</div>
<div class="line"><a id="l00307" name="l00307"></a><span class="lineno">  307</span> </div>
<div class="line"><a id="l00308" name="l00308"></a><span class="lineno">  308</span>    <span class="comment">// 更新线程池</span></div>
<div class="line"><a id="l00309" name="l00309"></a><span class="lineno">  309</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a> = tailTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a>;</div>
<div class="line"><a id="l00310" name="l00310"></a><span class="lineno">  310</span>    tailTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a>-&gt;<a class="code hl_variable" href="structthread_msg.html#affe4d46391e29e73eba06baa6897baac">nextTrdMsgStPt</a> = trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>;</div>
<div class="line"><a id="l00311" name="l00311"></a><span class="lineno">  311</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">activeThreadsCot</a> --;</div>
<div class="line"><a id="l00312" name="l00312"></a><span class="lineno">  312</span>    <span class="comment">// 更新表尾线程信息</span></div>
<div class="line"><a id="l00313" name="l00313"></a><span class="lineno">  313</span>    <span class="keywordflow">if</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0a0f5965804f3bc796600f6ecf66ba20">shutDown</a> == <span class="keyword">false</span>)</div>
<div class="line"><a id="l00314" name="l00314"></a><span class="lineno">  314</span>    {</div>
<div class="line"><a id="l00315" name="l00315"></a><span class="lineno">  315</span>        <span class="comment">// 线程未启动销毁</span></div>
<div class="line"><a id="l00316" name="l00316"></a><span class="lineno">  316</span>        <span class="comment">// 主动取消线程</span></div>
<div class="line"><a id="l00317" name="l00317"></a><span class="lineno">  317</span>        pthread_cancel(tailTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#ae68dfff2f96d2414dfbd3959a79e1b43">tid</a>);</div>
<div class="line"><a id="l00318" name="l00318"></a><span class="lineno">  318</span>    }</div>
<div class="line"><a id="l00319" name="l00319"></a><span class="lineno">  319</span>    <span class="keywordflow">else</span> </div>
<div class="line"><a id="l00320" name="l00320"></a><span class="lineno">  320</span>    {</div>
<div class="line"><a id="l00321" name="l00321"></a><span class="lineno">  321</span>        <span class="comment">// 线程启动销毁</span></div>
<div class="line"><a id="l00322" name="l00322"></a><span class="lineno">  322</span>        <span class="comment">// 接合退出的线程</span></div>
<div class="line"><a id="l00323" name="l00323"></a><span class="lineno">  323</span>        pthread_join(tailTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#ae68dfff2f96d2414dfbd3959a79e1b43">tid</a>, NULL);</div>
<div class="line"><a id="l00324" name="l00324"></a><span class="lineno">  324</span>    }</div>
<div class="line"><a id="l00325" name="l00325"></a><span class="lineno">  325</span>    tailTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">prevTrdMsgStPt</a> = tailTrdMsgStPt;</div>
<div class="line"><a id="l00326" name="l00326"></a><span class="lineno">  326</span>    tailTrdMsgStPt-&gt;<a class="code hl_variable" href="structthread_msg.html#affe4d46391e29e73eba06baa6897baac">nextTrdMsgStPt</a> = tailTrdMsgStPt;</div>
<div class="line"><a id="l00327" name="l00327"></a><span class="lineno">  327</span> </div>
<div class="line"><a id="l00328" name="l00328"></a><span class="lineno">  328</span>    <span class="comment">// 释放表尾线程信息内存</span></div>
<div class="line"><a id="l00329" name="l00329"></a><span class="lineno">  329</span>    free(tailTrdMsgStPt);</div>
<div class="line"><a id="l00330" name="l00330"></a><span class="lineno">  330</span>}</div>
</div>
<div class="line"><a id="l00331" name="l00331"></a><span class="lineno">  331</span> </div>
<div class="foldopen" id="foldopen00341" data-start="{" data-end="}">
<div class="line"><a id="l00341" name="l00341"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#a9fd17f658f3015bed2089a4acd9dda5a">  341</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#a9fd17f658f3015bed2089a4acd9dda5a">insertSomeNewThreadMsgs</a> (</div>
<div class="line"><a id="l00342" name="l00342"></a><span class="lineno">  342</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt,    </div>
<div class="line"><a id="l00343" name="l00343"></a><span class="lineno">  343</span>    <span class="keywordtype">int</span> newTrdMSgsCot                       </div>
<div class="line"><a id="l00344" name="l00344"></a><span class="lineno">  344</span>)</div>
<div class="line"><a id="l00345" name="l00345"></a><span class="lineno">  345</span>{</div>
<div class="line"><a id="l00346" name="l00346"></a><span class="lineno">  346</span>    <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; newTrdMSgsCot; i ++)</div>
<div class="line"><a id="l00347" name="l00347"></a><span class="lineno">  347</span>    {</div>
<div class="line"><a id="l00348" name="l00348"></a><span class="lineno">  348</span>        <span class="comment">// 新线程信息地址</span></div>
<div class="line"><a id="l00349" name="l00349"></a><span class="lineno">  349</span>        <a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st_pt</a> newTrdMsgStPt;</div>
<div class="line"><a id="l00350" name="l00350"></a><span class="lineno">  350</span>        <span class="comment">// 获取新线程信息</span></div>
<div class="line"><a id="l00351" name="l00351"></a><span class="lineno">  351</span>        newTrdMsgStPt = <a class="code hl_function" href="threads__pool_8c.html#a6c30c7bb23d59ef4146a65f8fc66976f">getNewThreadMsg</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00352" name="l00352"></a><span class="lineno">  352</span>        <span class="comment">// 插入新线程信息</span></div>
<div class="line"><a id="l00353" name="l00353"></a><span class="lineno">  353</span>        <a class="code hl_function" href="threads__pool_8c.html#a230969f5746c1add90070d33c4ac7092">insertNewThreadMsg</a>(trdsPolMsgStPt, newTrdMsgStPt);</div>
<div class="line"><a id="l00354" name="l00354"></a><span class="lineno">  354</span>    }</div>
<div class="line"><a id="l00355" name="l00355"></a><span class="lineno">  355</span>}</div>
</div>
<div class="line"><a id="l00356" name="l00356"></a><span class="lineno">  356</span> </div>
<div class="foldopen" id="foldopen00366" data-start="{" data-end="}">
<div class="line"><a id="l00366" name="l00366"></a><span class="lineno"><a class="line" href="threads__pool_8h.html#a871605529dee3dac1537de63589ab108">  366</a></span><a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> <a class="code hl_function" href="threads__pool_8c.html#a871605529dee3dac1537de63589ab108">getNewThreadsPoolMsg</a> (</div>
<div class="line"><a id="l00367" name="l00367"></a><span class="lineno">  367</span>    <span class="keywordtype">int</span> orgActiveThreadsCot,                </div>
<div class="line"><a id="l00368" name="l00368"></a><span class="lineno">  368</span>    <span class="keywordtype">int</span> maxWaitingTasksCot,                 </div>
<div class="line"><a id="l00369" name="l00369"></a><span class="lineno">  369</span>    <span class="keywordtype">int</span> maxActiveThreadsCot                 </div>
<div class="line"><a id="l00370" name="l00370"></a><span class="lineno">  370</span>)</div>
<div class="line"><a id="l00371" name="l00371"></a><span class="lineno">  371</span>{</div>
<div class="line"><a id="l00372" name="l00372"></a><span class="lineno">  372</span>    <span class="comment">// 新线程池信息地址</span></div>
<div class="line"><a id="l00373" name="l00373"></a><span class="lineno">  373</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> newTrdsPolMsgStPt;</div>
<div class="line"><a id="l00374" name="l00374"></a><span class="lineno">  374</span> </div>
<div class="line"><a id="l00375" name="l00375"></a><span class="lineno">  375</span>    <span class="comment">// 分配新线程池信息地址内存</span></div>
<div class="line"><a id="l00376" name="l00376"></a><span class="lineno">  376</span>    newTrdsPolMsgStPt = malloc(<span class="keyword">sizeof</span>(<a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st</a>));</div>
<div class="line"><a id="l00377" name="l00377"></a><span class="lineno">  377</span> </div>
<div class="line"><a id="l00378" name="l00378"></a><span class="lineno">  378</span>    <span class="comment">// 初始化新线程池信息</span></div>
<div class="line"><a id="l00379" name="l00379"></a><span class="lineno">  379</span>    pthread_mutex_init(&amp;newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>, NULL);</div>
<div class="line"><a id="l00380" name="l00380"></a><span class="lineno">  380</span>    pthread_cond_init(&amp;newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0fb5277da524002442dfdd04bd95a852">codUn</a>, NULL);</div>
<div class="line"><a id="l00381" name="l00381"></a><span class="lineno">  381</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0a0f5965804f3bc796600f6ecf66ba20">shutDown</a> = <span class="keyword">false</span>;</div>
<div class="line"><a id="l00382" name="l00382"></a><span class="lineno">  382</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> = 0;</div>
<div class="line"><a id="l00383" name="l00383"></a><span class="lineno">  383</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">activeThreadsCot</a> = 0;</div>
<div class="line"><a id="l00384" name="l00384"></a><span class="lineno">  384</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a78a0c6c3b579b2099ac3e12e8e5ada62">maxWaitingTasksCot</a> = maxWaitingTasksCot;</div>
<div class="line"><a id="l00385" name="l00385"></a><span class="lineno">  385</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aa383e3c726e24f65bd04b8559d74afec">maxActiveThreadsCot</a> = maxActiveThreadsCot;</div>
<div class="line"><a id="l00386" name="l00386"></a><span class="lineno">  386</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a> = <a class="code hl_function" href="threads__pool_8c.html#a4ebf31958db9354ac6dcdb000e723303">getNewTaskMsg</a>(NULL, NULL);</div>
<div class="line"><a id="l00387" name="l00387"></a><span class="lineno">  387</span>    newTrdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a> = <a class="code hl_function" href="threads__pool_8c.html#a6c30c7bb23d59ef4146a65f8fc66976f">getNewThreadMsg</a>(NULL);</div>
<div class="line"><a id="l00388" name="l00388"></a><span class="lineno">  388</span>    <a class="code hl_function" href="threads__pool_8c.html#a9fd17f658f3015bed2089a4acd9dda5a">insertSomeNewThreadMsgs</a>(newTrdsPolMsgStPt, orgActiveThreadsCot);</div>
<div class="line"><a id="l00389" name="l00389"></a><span class="lineno">  389</span> </div>
<div class="line"><a id="l00390" name="l00390"></a><span class="lineno">  390</span>    <span class="keywordflow">return</span> newTrdsPolMsgStPt;</div>
<div class="line"><a id="l00391" name="l00391"></a><span class="lineno">  391</span>}</div>
</div>
<div class="line"><a id="l00392" name="l00392"></a><span class="lineno">  392</span> </div>
<div class="foldopen" id="foldopen00396" data-start="{" data-end="}">
<div class="line"><a id="l00396" name="l00396"></a><span class="lineno"><a class="line" href="threads__pool_8h.html#a3ceec63a2e1c63606f561486b0b24e72">  396</a></span><span class="keywordtype">int</span> <a class="code hl_function" href="threads__pool_8c.html#a3ceec63a2e1c63606f561486b0b24e72">addNewTask</a> (</div>
<div class="line"><a id="l00397" name="l00397"></a><span class="lineno">  397</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt,    </div>
<div class="line"><a id="l00398" name="l00398"></a><span class="lineno">  398</span>    <span class="keywordtype">void</span>* (* handleFuncPt)(<span class="keywordtype">void</span>* arg),      </div>
<div class="line"><a id="l00399" name="l00399"></a><span class="lineno">  399</span>    <span class="keywordtype">void</span>* handleFuncArg                     </div>
<div class="line"><a id="l00400" name="l00400"></a><span class="lineno">  400</span>)</div>
<div class="line"><a id="l00401" name="l00401"></a><span class="lineno">  401</span>{</div>
<div class="line"><a id="l00402" name="l00402"></a><span class="lineno">  402</span>    <span class="comment">/* +++++++++++++++++++ 压栈预清理函数并加锁 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00403" name="l00403"></a><span class="lineno">  403</span>    <a class="code hl_define" href="threads__pool_8h.html#ade228054bfa068c8720ccbdd9bd60f1f">READY_CLEAN_UP_AND_LOCK</a>(<a class="code hl_function" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a>, &amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00404" name="l00404"></a><span class="lineno">  404</span>    <span class="comment">/* ↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓ */</span></div>
<div class="line"><a id="l00405" name="l00405"></a><span class="lineno">  405</span>    <span class="keywordflow">if</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> &gt;= trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a78a0c6c3b579b2099ac3e12e8e5ada62">maxWaitingTasksCot</a>)</div>
<div class="line"><a id="l00406" name="l00406"></a><span class="lineno">  406</span>    {</div>
<div class="line"><a id="l00407" name="l00407"></a><span class="lineno">  407</span>        fprintf(stderr, <span class="stringliteral">&quot;等待任务量过多，无法添加。\n&quot;</span>);</div>
<div class="line"><a id="l00408" name="l00408"></a><span class="lineno">  408</span>        <span class="keywordflow">return</span> -1;</div>
<div class="line"><a id="l00409" name="l00409"></a><span class="lineno">  409</span>    }</div>
<div class="line"><a id="l00410" name="l00410"></a><span class="lineno">  410</span> </div>
<div class="line"><a id="l00411" name="l00411"></a><span class="lineno">  411</span>    <span class="comment">// 新任务信息地址</span></div>
<div class="line"><a id="l00412" name="l00412"></a><span class="lineno">  412</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> newTaskMsgStPt;</div>
<div class="line"><a id="l00413" name="l00413"></a><span class="lineno">  413</span> </div>
<div class="line"><a id="l00414" name="l00414"></a><span class="lineno">  414</span>    <span class="comment">// 获取新任务信息</span></div>
<div class="line"><a id="l00415" name="l00415"></a><span class="lineno">  415</span>    newTaskMsgStPt = <a class="code hl_function" href="threads__pool_8c.html#a4ebf31958db9354ac6dcdb000e723303">getNewTaskMsg</a>(handleFuncPt, handleFuncArg);</div>
<div class="line"><a id="l00416" name="l00416"></a><span class="lineno">  416</span> </div>
<div class="line"><a id="l00417" name="l00417"></a><span class="lineno">  417</span>    <span class="comment">// 入队新任务信息</span></div>
<div class="line"><a id="l00418" name="l00418"></a><span class="lineno">  418</span>    <a class="code hl_function" href="threads__pool_8c.html#ab8f5739158324ca3499012ae04bce8cd">inqueueNewTaskMsg</a>(trdsPolMsgStPt, newTaskMsgStPt);</div>
<div class="line"><a id="l00419" name="l00419"></a><span class="lineno">  419</span>    <span class="comment">/* ↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ */</span></div>
<div class="line"><a id="l00420" name="l00420"></a><span class="lineno">  420</span>    <a class="code hl_define" href="threads__pool_8h.html#aad77b3322f3824da508dfbd0d04aa1a3">UNLOCK_AND_CANCEL_CLEAN_UP</a>(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00421" name="l00421"></a><span class="lineno">  421</span>    <span class="comment">/* +++++++++++++++++++ 解锁并出栈预清理函数 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00422" name="l00422"></a><span class="lineno">  422</span>    <span class="comment">// 唤醒所有等待中的线程，通知新任务可执行</span></div>
<div class="line"><a id="l00423" name="l00423"></a><span class="lineno">  423</span>    pthread_cond_broadcast(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0fb5277da524002442dfdd04bd95a852">codUn</a>);</div>
<div class="line"><a id="l00424" name="l00424"></a><span class="lineno">  424</span> </div>
<div class="line"><a id="l00425" name="l00425"></a><span class="lineno">  425</span>    <span class="keywordflow">return</span> 0;</div>
<div class="line"><a id="l00426" name="l00426"></a><span class="lineno">  426</span>}</div>
</div>
<div class="line"><a id="l00427" name="l00427"></a><span class="lineno">  427</span> </div>
<div class="foldopen" id="foldopen00431" data-start="{" data-end="}">
<div class="line"><a id="l00431" name="l00431"></a><span class="lineno"><a class="line" href="threads__pool_8h.html#a7ebefc9eea4454da73914b2e62c3ef54">  431</a></span><span class="keywordtype">int</span> <a class="code hl_function" href="threads__pool_8c.html#a7ebefc9eea4454da73914b2e62c3ef54">reduceTask</a> (</div>
<div class="line"><a id="l00432" name="l00432"></a><span class="lineno">  432</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt,    </div>
<div class="line"><a id="l00433" name="l00433"></a><span class="lineno">  433</span>    <span class="keywordtype">void</span>* (* destHandleFuncPt)(<span class="keywordtype">void</span>* arg)   </div>
<div class="line"><a id="l00434" name="l00434"></a><span class="lineno">  434</span>)</div>
<div class="line"><a id="l00435" name="l00435"></a><span class="lineno">  435</span>{</div>
<div class="line"><a id="l00436" name="l00436"></a><span class="lineno">  436</span>    <span class="comment">/* +++++++++++++++++++ 压栈预清理函数并加锁 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00437" name="l00437"></a><span class="lineno">  437</span>    <a class="code hl_define" href="threads__pool_8h.html#ade228054bfa068c8720ccbdd9bd60f1f">READY_CLEAN_UP_AND_LOCK</a>(<a class="code hl_function" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a>, &amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00438" name="l00438"></a><span class="lineno">  438</span>    <span class="comment">/* ↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓ */</span></div>
<div class="line"><a id="l00439" name="l00439"></a><span class="lineno">  439</span>    <span class="keywordflow">if</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> &lt;= 0)</div>
<div class="line"><a id="l00440" name="l00440"></a><span class="lineno">  440</span>    {</div>
<div class="line"><a id="l00441" name="l00441"></a><span class="lineno">  441</span>        fprintf(stderr, <span class="stringliteral">&quot;无等待任务，无法减少。\n&quot;</span>);</div>
<div class="line"><a id="l00442" name="l00442"></a><span class="lineno">  442</span>        <span class="keywordflow">return</span> -1;        </div>
<div class="line"><a id="l00443" name="l00443"></a><span class="lineno">  443</span>    }</div>
<div class="line"><a id="l00444" name="l00444"></a><span class="lineno">  444</span> </div>
<div class="line"><a id="l00445" name="l00445"></a><span class="lineno">  445</span>    <a class="code hl_function" href="threads__pool_8c.html#a8a38ce3bf239e8daae72e3d7f7fc66a7">removeDestTaskMsg</a>(trdsPolMsgStPt, destHandleFuncPt);</div>
<div class="line"><a id="l00446" name="l00446"></a><span class="lineno">  446</span>    <span class="comment">/* ↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ */</span></div>
<div class="line"><a id="l00447" name="l00447"></a><span class="lineno">  447</span>    <a class="code hl_define" href="threads__pool_8h.html#aad77b3322f3824da508dfbd0d04aa1a3">UNLOCK_AND_CANCEL_CLEAN_UP</a>(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00448" name="l00448"></a><span class="lineno">  448</span>    <span class="comment">/* +++++++++++++++++++ 解锁并出栈预清理函数 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00449" name="l00449"></a><span class="lineno">  449</span> </div>
<div class="line"><a id="l00450" name="l00450"></a><span class="lineno">  450</span>    <span class="keywordflow">return</span> 0;</div>
<div class="line"><a id="l00451" name="l00451"></a><span class="lineno">  451</span>}</div>
</div>
<div class="line"><a id="l00452" name="l00452"></a><span class="lineno">  452</span> </div>
<div class="foldopen" id="foldopen00456" data-start="{" data-end="}">
<div class="line"><a id="l00456" name="l00456"></a><span class="lineno"><a class="line" href="threads__pool_8h.html#a3c97656e7bb9d4709eca4ed29abf9d9c">  456</a></span><span class="keywordtype">int</span> <a class="code hl_function" href="threads__pool_8c.html#a3c97656e7bb9d4709eca4ed29abf9d9c">addThread</a> (</div>
<div class="line"><a id="l00457" name="l00457"></a><span class="lineno">  457</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00458" name="l00458"></a><span class="lineno">  458</span>)</div>
<div class="line"><a id="l00459" name="l00459"></a><span class="lineno">  459</span>{</div>
<div class="line"><a id="l00460" name="l00460"></a><span class="lineno">  460</span>    <span class="comment">/* +++++++++++++++++++ 压栈预清理函数并加锁 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00461" name="l00461"></a><span class="lineno">  461</span>    <a class="code hl_define" href="threads__pool_8h.html#ade228054bfa068c8720ccbdd9bd60f1f">READY_CLEAN_UP_AND_LOCK</a>(<a class="code hl_function" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a>, &amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00462" name="l00462"></a><span class="lineno">  462</span>    <span class="comment">/* ↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓ */</span></div>
<div class="line"><a id="l00463" name="l00463"></a><span class="lineno">  463</span>    <span class="keywordflow">if</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">activeThreadsCot</a> &gt;= trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aa383e3c726e24f65bd04b8559d74afec">maxActiveThreadsCot</a>)</div>
<div class="line"><a id="l00464" name="l00464"></a><span class="lineno">  464</span>    {</div>
<div class="line"><a id="l00465" name="l00465"></a><span class="lineno">  465</span>        fprintf(stderr, <span class="stringliteral">&quot;活跃线程量过多，无法添加。\n&quot;</span>);</div>
<div class="line"><a id="l00466" name="l00466"></a><span class="lineno">  466</span>        <span class="keywordflow">return</span> -1;        </div>
<div class="line"><a id="l00467" name="l00467"></a><span class="lineno">  467</span>    }</div>
<div class="line"><a id="l00468" name="l00468"></a><span class="lineno">  468</span> </div>
<div class="line"><a id="l00469" name="l00469"></a><span class="lineno">  469</span>    <span class="comment">// 新线程信息地址</span></div>
<div class="line"><a id="l00470" name="l00470"></a><span class="lineno">  470</span>    <a class="code hl_struct" href="structthread_msg.html">ThreadMsg_st_pt</a> newTrdMsgStPt;</div>
<div class="line"><a id="l00471" name="l00471"></a><span class="lineno">  471</span> </div>
<div class="line"><a id="l00472" name="l00472"></a><span class="lineno">  472</span>    <span class="comment">// 获取新线程信息</span></div>
<div class="line"><a id="l00473" name="l00473"></a><span class="lineno">  473</span>    newTrdMsgStPt = <a class="code hl_function" href="threads__pool_8c.html#a6c30c7bb23d59ef4146a65f8fc66976f">getNewThreadMsg</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00474" name="l00474"></a><span class="lineno">  474</span>    <span class="comment">// 插入新线程</span></div>
<div class="line"><a id="l00475" name="l00475"></a><span class="lineno">  475</span>    <a class="code hl_function" href="threads__pool_8c.html#a230969f5746c1add90070d33c4ac7092">insertNewThreadMsg</a>(trdsPolMsgStPt, newTrdMsgStPt);</div>
<div class="line"><a id="l00476" name="l00476"></a><span class="lineno">  476</span>    <span class="comment">/* ↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ */</span></div>
<div class="line"><a id="l00477" name="l00477"></a><span class="lineno">  477</span>    <a class="code hl_define" href="threads__pool_8h.html#aad77b3322f3824da508dfbd0d04aa1a3">UNLOCK_AND_CANCEL_CLEAN_UP</a>(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00478" name="l00478"></a><span class="lineno">  478</span>    <span class="comment">/* +++++++++++++++++++ 解锁并出栈预清理函数 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00479" name="l00479"></a><span class="lineno">  479</span> </div>
<div class="line"><a id="l00480" name="l00480"></a><span class="lineno">  480</span>    <span class="keywordflow">return</span> 0;    </div>
<div class="line"><a id="l00481" name="l00481"></a><span class="lineno">  481</span>}</div>
</div>
<div class="line"><a id="l00482" name="l00482"></a><span class="lineno">  482</span> </div>
<div class="foldopen" id="foldopen00486" data-start="{" data-end="}">
<div class="line"><a id="l00486" name="l00486"></a><span class="lineno"><a class="line" href="threads__pool_8h.html#afbfdf354a44f65186b3dfdd80e566b59">  486</a></span><span class="keywordtype">int</span> <a class="code hl_function" href="threads__pool_8c.html#afbfdf354a44f65186b3dfdd80e566b59">reduceThread</a> (</div>
<div class="line"><a id="l00487" name="l00487"></a><span class="lineno">  487</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00488" name="l00488"></a><span class="lineno">  488</span>)</div>
<div class="line"><a id="l00489" name="l00489"></a><span class="lineno">  489</span>{</div>
<div class="line"><a id="l00490" name="l00490"></a><span class="lineno">  490</span>    <span class="comment">/* +++++++++++++++++++ 压栈预清理函数并加锁 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00491" name="l00491"></a><span class="lineno">  491</span>    <a class="code hl_define" href="threads__pool_8h.html#ade228054bfa068c8720ccbdd9bd60f1f">READY_CLEAN_UP_AND_LOCK</a>(<a class="code hl_function" href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a>, &amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00492" name="l00492"></a><span class="lineno">  492</span>    <span class="comment">/* ↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓↓ */</span></div>
<div class="line"><a id="l00493" name="l00493"></a><span class="lineno">  493</span>    <span class="keywordflow">if</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">activeThreadsCot</a> &lt;= 1)</div>
<div class="line"><a id="l00494" name="l00494"></a><span class="lineno">  494</span>    {</div>
<div class="line"><a id="l00495" name="l00495"></a><span class="lineno">  495</span>        fprintf(stderr, <span class="stringliteral">&quot;只有一个活跃线程，无法减少。\n&quot;</span>);</div>
<div class="line"><a id="l00496" name="l00496"></a><span class="lineno">  496</span>        <span class="keywordflow">return</span> -1;        </div>
<div class="line"><a id="l00497" name="l00497"></a><span class="lineno">  497</span>    }</div>
<div class="line"><a id="l00498" name="l00498"></a><span class="lineno">  498</span> </div>
<div class="line"><a id="l00499" name="l00499"></a><span class="lineno">  499</span>    <a class="code hl_function" href="threads__pool_8c.html#a14fc4d285be60008c10b4c2520d770f4">removeThreadMsg</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00500" name="l00500"></a><span class="lineno">  500</span>    <span class="comment">/* ↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑↑ */</span></div>
<div class="line"><a id="l00501" name="l00501"></a><span class="lineno">  501</span>    <a class="code hl_define" href="threads__pool_8h.html#aad77b3322f3824da508dfbd0d04aa1a3">UNLOCK_AND_CANCEL_CLEAN_UP</a>(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00502" name="l00502"></a><span class="lineno">  502</span>    <span class="comment">/* +++++++++++++++++++ 解锁并出栈预清理函数 +++++++++++++++++++ */</span></div>
<div class="line"><a id="l00503" name="l00503"></a><span class="lineno">  503</span> </div>
<div class="line"><a id="l00504" name="l00504"></a><span class="lineno">  504</span>    <span class="keywordflow">return</span> 0;        </div>
<div class="line"><a id="l00505" name="l00505"></a><span class="lineno">  505</span>}</div>
</div>
<div class="line"><a id="l00506" name="l00506"></a><span class="lineno">  506</span> </div>
<div class="foldopen" id="foldopen00513" data-start="{" data-end="}">
<div class="line"><a id="l00513" name="l00513"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#aad05cdcc30cc4fd66e4ff890ea5cb570">  513</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#aad05cdcc30cc4fd66e4ff890ea5cb570">destroyThreadMsgsLinkedList</a> (</div>
<div class="line"><a id="l00514" name="l00514"></a><span class="lineno">  514</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00515" name="l00515"></a><span class="lineno">  515</span>)</div>
<div class="line"><a id="l00516" name="l00516"></a><span class="lineno">  516</span>{    </div>
<div class="line"><a id="l00517" name="l00517"></a><span class="lineno">  517</span>    <span class="comment">// 唤醒所有等待新任务的线程</span></div>
<div class="line"><a id="l00518" name="l00518"></a><span class="lineno">  518</span>    pthread_cond_broadcast(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0fb5277da524002442dfdd04bd95a852">codUn</a>);</div>
<div class="line"><a id="l00519" name="l00519"></a><span class="lineno">  519</span>    <span class="keywordflow">while</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">activeThreadsCot</a> &gt; 0)</div>
<div class="line"><a id="l00520" name="l00520"></a><span class="lineno">  520</span>    {</div>
<div class="line"><a id="l00521" name="l00521"></a><span class="lineno">  521</span>        <span class="comment">// 存在线程信息</span></div>
<div class="line"><a id="l00522" name="l00522"></a><span class="lineno">  522</span>        <span class="comment">// 删除线程信息</span></div>
<div class="line"><a id="l00523" name="l00523"></a><span class="lineno">  523</span>        <a class="code hl_function" href="threads__pool_8c.html#a14fc4d285be60008c10b4c2520d770f4">removeThreadMsg</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00524" name="l00524"></a><span class="lineno">  524</span>    }    </div>
<div class="line"><a id="l00525" name="l00525"></a><span class="lineno">  525</span>    <span class="comment">// 释放线程链表入口内存</span></div>
<div class="line"><a id="l00526" name="l00526"></a><span class="lineno">  526</span>    free(trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsLinkedListEntr</a>);</div>
<div class="line"><a id="l00527" name="l00527"></a><span class="lineno">  527</span>}</div>
</div>
<div class="line"><a id="l00528" name="l00528"></a><span class="lineno">  528</span> </div>
<div class="foldopen" id="foldopen00535" data-start="{" data-end="}">
<div class="line"><a id="l00535" name="l00535"></a><span class="lineno"><a class="line" href="threads__pool_8c.html#af6ab15dabb1e0688a886e468d0f0b577">  535</a></span><span class="keyword">static</span> <span class="keyword">inline</span> <span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#af6ab15dabb1e0688a886e468d0f0b577">destroyTaskMsgsLinkedQueue</a> (</div>
<div class="line"><a id="l00536" name="l00536"></a><span class="lineno">  536</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00537" name="l00537"></a><span class="lineno">  537</span>)</div>
<div class="line"><a id="l00538" name="l00538"></a><span class="lineno">  538</span>{</div>
<div class="line"><a id="l00539" name="l00539"></a><span class="lineno">  539</span>    <span class="comment">// 任务信息地址</span></div>
<div class="line"><a id="l00540" name="l00540"></a><span class="lineno">  540</span>    <a class="code hl_struct" href="structtask_msg.html">TaskMsg_st_pt</a> taskMsgStPt;</div>
<div class="line"><a id="l00541" name="l00541"></a><span class="lineno">  541</span> </div>
<div class="line"><a id="l00542" name="l00542"></a><span class="lineno">  542</span>    <span class="keywordflow">while</span> (trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">waitingTasksCot</a> &gt; 0)</div>
<div class="line"><a id="l00543" name="l00543"></a><span class="lineno">  543</span>    {</div>
<div class="line"><a id="l00544" name="l00544"></a><span class="lineno">  544</span>        <span class="comment">// 获取队头任务信息</span></div>
<div class="line"><a id="l00545" name="l00545"></a><span class="lineno">  545</span>        taskMsgStPt = <a class="code hl_function" href="threads__pool_8c.html#af90c938ee855b735b0c0b9f82f9e6d67">dequeueTaskMsg</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00546" name="l00546"></a><span class="lineno">  546</span>        <span class="comment">// 释放队头任务信息内存</span></div>
<div class="line"><a id="l00547" name="l00547"></a><span class="lineno">  547</span>        free (taskMsgStPt);</div>
<div class="line"><a id="l00548" name="l00548"></a><span class="lineno">  548</span>    }    </div>
<div class="line"><a id="l00549" name="l00549"></a><span class="lineno">  549</span>    <span class="comment">// 释放任务链队入口内存</span></div>
<div class="line"><a id="l00550" name="l00550"></a><span class="lineno">  550</span>    free(trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">tasksLinkedQueueEntr</a>);</div>
<div class="line"><a id="l00551" name="l00551"></a><span class="lineno">  551</span>}</div>
</div>
<div class="line"><a id="l00552" name="l00552"></a><span class="lineno">  552</span> </div>
<div class="foldopen" id="foldopen00556" data-start="{" data-end="}">
<div class="line"><a id="l00556" name="l00556"></a><span class="lineno"><a class="line" href="threads__pool_8h.html#a9ebf8832444bfb71e5cc1549ec38e354">  556</a></span><span class="keywordtype">void</span> <a class="code hl_function" href="threads__pool_8c.html#a9ebf8832444bfb71e5cc1549ec38e354">destroyThreadsPoolMsg</a> (</div>
<div class="line"><a id="l00557" name="l00557"></a><span class="lineno">  557</span>    <a class="code hl_struct" href="structthreads_pool_msg.html">ThreadsPoolMsg_st_pt</a> trdsPolMsgStPt </div>
<div class="line"><a id="l00558" name="l00558"></a><span class="lineno">  558</span>)</div>
<div class="line"><a id="l00559" name="l00559"></a><span class="lineno">  559</span>{</div>
<div class="line"><a id="l00560" name="l00560"></a><span class="lineno">  560</span>    <span class="comment">// 启动线程池销毁</span></div>
<div class="line"><a id="l00561" name="l00561"></a><span class="lineno">  561</span>    trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0a0f5965804f3bc796600f6ecf66ba20">shutDown</a> = <span class="keyword">true</span>;</div>
<div class="line"><a id="l00562" name="l00562"></a><span class="lineno">  562</span>    <span class="comment">// 销毁线程信息链表</span></div>
<div class="line"><a id="l00563" name="l00563"></a><span class="lineno">  563</span>    <a class="code hl_function" href="threads__pool_8c.html#aad05cdcc30cc4fd66e4ff890ea5cb570">destroyThreadMsgsLinkedList</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00564" name="l00564"></a><span class="lineno">  564</span>    <span class="comment">// 销毁任务信息链队</span></div>
<div class="line"><a id="l00565" name="l00565"></a><span class="lineno">  565</span>    <a class="code hl_function" href="threads__pool_8c.html#af6ab15dabb1e0688a886e468d0f0b577">destroyTaskMsgsLinkedQueue</a>(trdsPolMsgStPt);</div>
<div class="line"><a id="l00566" name="l00566"></a><span class="lineno">  566</span>    <span class="comment">// 销毁互斥锁</span></div>
<div class="line"><a id="l00567" name="l00567"></a><span class="lineno">  567</span>    pthread_mutex_destroy(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">mtxUn</a>);</div>
<div class="line"><a id="l00568" name="l00568"></a><span class="lineno">  568</span>    <span class="comment">// 销毁条件量</span></div>
<div class="line"><a id="l00569" name="l00569"></a><span class="lineno">  569</span>    pthread_cond_destroy(&amp;trdsPolMsgStPt-&gt;<a class="code hl_variable" href="structthreads_pool_msg.html#a0fb5277da524002442dfdd04bd95a852">codUn</a>);</div>
<div class="line"><a id="l00570" name="l00570"></a><span class="lineno">  570</span>    <span class="comment">// 释放线程池信息内存</span></div>
<div class="line"><a id="l00571" name="l00571"></a><span class="lineno">  571</span>    free(trdsPolMsgStPt);</div>
<div class="line"><a id="l00572" name="l00572"></a><span class="lineno">  572</span>}</div>
</div>
<div class="line"><a id="l00573" name="l00573"></a><span class="lineno">  573</span> </div>
<div class="line"><a id="l00574" name="l00574"></a><span class="lineno">  574</span><span class="preprocessor">#endif</span></div>
<div class="ttc" id="astructtask_msg_html"><div class="ttname"><a href="structtask_msg.html">taskMsg</a></div><div class="ttdoc">任务信息结构体</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00030">threads_pool.h:32</a></div></div>
<div class="ttc" id="astructtask_msg_html_a320a82ee2a68ce91e1c149979d694665"><div class="ttname"><a href="structtask_msg.html#a320a82ee2a68ce91e1c149979d694665">taskMsg::handleFuncPt</a></div><div class="ttdeci">void *(* handleFuncPt)(void *arg)</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00033">threads_pool.h:33</a></div></div>
<div class="ttc" id="astructtask_msg_html_a9efefa9e58ba07cae75d220d1b25c435"><div class="ttname"><a href="structtask_msg.html#a9efefa9e58ba07cae75d220d1b25c435">taskMsg::handleFuncArg</a></div><div class="ttdeci">void * handleFuncArg</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00034">threads_pool.h:34</a></div></div>
<div class="ttc" id="astructtask_msg_html_ad40256cce6dd56cb02e7125af66452d9"><div class="ttname"><a href="structtask_msg.html#ad40256cce6dd56cb02e7125af66452d9">taskMsg::prevTaskMsgStPt</a></div><div class="ttdeci">struct taskMsg * prevTaskMsgStPt</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00035">threads_pool.h:35</a></div></div>
<div class="ttc" id="astructtask_msg_html_ae16f9516402596ed01dccf2233900c5e"><div class="ttname"><a href="structtask_msg.html#ae16f9516402596ed01dccf2233900c5e">taskMsg::nextTaskMsgStPt</a></div><div class="ttdeci">struct taskMsg * nextTaskMsgStPt</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00036">threads_pool.h:36</a></div></div>
<div class="ttc" id="astructthread_msg_html"><div class="ttname"><a href="structthread_msg.html">threadMsg</a></div><div class="ttdoc">线程信息结构体</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00044">threads_pool.h:46</a></div></div>
<div class="ttc" id="astructthread_msg_html_a57a24de45c24628dfe6fb14cd10a868a"><div class="ttname"><a href="structthread_msg.html#a57a24de45c24628dfe6fb14cd10a868a">threadMsg::prevTrdMsgStPt</a></div><div class="ttdeci">struct threadMsg * prevTrdMsgStPt</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00048">threads_pool.h:48</a></div></div>
<div class="ttc" id="astructthread_msg_html_ae68dfff2f96d2414dfbd3959a79e1b43"><div class="ttname"><a href="structthread_msg.html#ae68dfff2f96d2414dfbd3959a79e1b43">threadMsg::tid</a></div><div class="ttdeci">pthread_t tid</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00047">threads_pool.h:47</a></div></div>
<div class="ttc" id="astructthread_msg_html_affe4d46391e29e73eba06baa6897baac"><div class="ttname"><a href="structthread_msg.html#affe4d46391e29e73eba06baa6897baac">threadMsg::nextTrdMsgStPt</a></div><div class="ttdeci">struct threadMsg * nextTrdMsgStPt</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00049">threads_pool.h:49</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html"><div class="ttname"><a href="structthreads_pool_msg.html">threadsPoolMsg</a></div><div class="ttdoc">线程池信息结构体</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00057">threads_pool.h:59</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a0a0f5965804f3bc796600f6ecf66ba20"><div class="ttname"><a href="structthreads_pool_msg.html#a0a0f5965804f3bc796600f6ecf66ba20">threadsPoolMsg::shutDown</a></div><div class="ttdeci">bool shutDown</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00062">threads_pool.h:62</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a0f16ca9c117fe8e1a878720fb801e4e1"><div class="ttname"><a href="structthreads_pool_msg.html#a0f16ca9c117fe8e1a878720fb801e4e1">threadsPoolMsg::threadsLinkedListEntr</a></div><div class="ttdeci">ThreadMsg_st_pt threadsLinkedListEntr</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00068">threads_pool.h:68</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a0fb5277da524002442dfdd04bd95a852"><div class="ttname"><a href="structthreads_pool_msg.html#a0fb5277da524002442dfdd04bd95a852">threadsPoolMsg::codUn</a></div><div class="ttdeci">pthread_cond_t codUn</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00061">threads_pool.h:61</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a67c4752b08cc34e3217c42abbbabd719"><div class="ttname"><a href="structthreads_pool_msg.html#a67c4752b08cc34e3217c42abbbabd719">threadsPoolMsg::activeThreadsCot</a></div><div class="ttdeci">int activeThreadsCot</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00064">threads_pool.h:64</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a78a0c6c3b579b2099ac3e12e8e5ada62"><div class="ttname"><a href="structthreads_pool_msg.html#a78a0c6c3b579b2099ac3e12e8e5ada62">threadsPoolMsg::maxWaitingTasksCot</a></div><div class="ttdeci">int maxWaitingTasksCot</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00065">threads_pool.h:65</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a80ed574e122423cf9ffafd4b2d1cfb9c"><div class="ttname"><a href="structthreads_pool_msg.html#a80ed574e122423cf9ffafd4b2d1cfb9c">threadsPoolMsg::mtxUn</a></div><div class="ttdeci">pthread_mutex_t mtxUn</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00060">threads_pool.h:60</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_a8281735069450c11d1154f0dce28f083"><div class="ttname"><a href="structthreads_pool_msg.html#a8281735069450c11d1154f0dce28f083">threadsPoolMsg::waitingTasksCot</a></div><div class="ttdeci">int waitingTasksCot</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00063">threads_pool.h:63</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_aa383e3c726e24f65bd04b8559d74afec"><div class="ttname"><a href="structthreads_pool_msg.html#aa383e3c726e24f65bd04b8559d74afec">threadsPoolMsg::maxActiveThreadsCot</a></div><div class="ttdeci">int maxActiveThreadsCot</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00066">threads_pool.h:66</a></div></div>
<div class="ttc" id="astructthreads_pool_msg_html_aefa9644b2c0e4132e99fd66a751fa38a"><div class="ttname"><a href="structthreads_pool_msg.html#aefa9644b2c0e4132e99fd66a751fa38a">threadsPoolMsg::tasksLinkedQueueEntr</a></div><div class="ttdeci">TaskMsg_st_pt tasksLinkedQueueEntr</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00067">threads_pool.h:67</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a14fc4d285be60008c10b4c2520d770f4"><div class="ttname"><a href="threads__pool_8c.html#a14fc4d285be60008c10b4c2520d770f4">removeThreadMsg</a></div><div class="ttdeci">static void removeThreadMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">从链表中移除线程信息</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00298">threads_pool.c:298</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a230969f5746c1add90070d33c4ac7092"><div class="ttname"><a href="threads__pool_8c.html#a230969f5746c1add90070d33c4ac7092">insertNewThreadMsg</a></div><div class="ttdeci">static void insertNewThreadMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt, ThreadMsg_st_pt newTrdMsgStPt)</div><div class="ttdoc">插入新线程信息到链表</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00276">threads_pool.c:276</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a3c97656e7bb9d4709eca4ed29abf9d9c"><div class="ttname"><a href="threads__pool_8c.html#a3c97656e7bb9d4709eca4ed29abf9d9c">addThread</a></div><div class="ttdeci">int addThread(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">向线程池中添加新线程</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00456">threads_pool.c:456</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a3ceec63a2e1c63606f561486b0b24e72"><div class="ttname"><a href="threads__pool_8c.html#a3ceec63a2e1c63606f561486b0b24e72">addNewTask</a></div><div class="ttdeci">int addNewTask(ThreadsPoolMsg_st_pt trdsPolMsgStPt, void *(*handleFuncPt)(void *arg), void *handleFuncArg)</div><div class="ttdoc">添加新任务到线程池</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00396">threads_pool.c:396</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a4ebf31958db9354ac6dcdb000e723303"><div class="ttname"><a href="threads__pool_8c.html#a4ebf31958db9354ac6dcdb000e723303">getNewTaskMsg</a></div><div class="ttdeci">static TaskMsg_st_pt getNewTaskMsg(void *(*handleFuncPt)(void *arg), void *handleFuncArg)</div><div class="ttdoc">创建新的任务信息</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00050">threads_pool.c:50</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a649af44a3d418d82c8be4cc9e28be41d"><div class="ttname"><a href="threads__pool_8c.html#a649af44a3d418d82c8be4cc9e28be41d">threadRoutine</a></div><div class="ttdeci">static void * threadRoutine(void *arg)</div><div class="ttdoc">线程例程函数</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00185">threads_pool.c:185</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a6c30c7bb23d59ef4146a65f8fc66976f"><div class="ttname"><a href="threads__pool_8c.html#a6c30c7bb23d59ef4146a65f8fc66976f">getNewThreadMsg</a></div><div class="ttdeci">static ThreadMsg_st_pt getNewThreadMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">创建新的线程信息</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00245">threads_pool.c:245</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a7ebefc9eea4454da73914b2e62c3ef54"><div class="ttname"><a href="threads__pool_8c.html#a7ebefc9eea4454da73914b2e62c3ef54">reduceTask</a></div><div class="ttdeci">int reduceTask(ThreadsPoolMsg_st_pt trdsPolMsgStPt, void *(*destHandleFuncPt)(void *arg))</div><div class="ttdoc">从线程池中移除指定任务</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00431">threads_pool.c:431</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a871605529dee3dac1537de63589ab108"><div class="ttname"><a href="threads__pool_8c.html#a871605529dee3dac1537de63589ab108">getNewThreadsPoolMsg</a></div><div class="ttdeci">ThreadsPoolMsg_st_pt getNewThreadsPoolMsg(int orgActiveThreadsCot, int maxWaitingTasksCot, int maxActiveThreadsCot)</div><div class="ttdoc">创建新的线程池</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00366">threads_pool.c:366</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a8a38ce3bf239e8daae72e3d7f7fc66a7"><div class="ttname"><a href="threads__pool_8c.html#a8a38ce3bf239e8daae72e3d7f7fc66a7">removeDestTaskMsg</a></div><div class="ttdeci">static int removeDestTaskMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt, void *(*destHandleFuncPt)(void *arg))</div><div class="ttdoc">移除指定任务信息</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00134">threads_pool.c:134</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a9ebf8832444bfb71e5cc1549ec38e354"><div class="ttname"><a href="threads__pool_8c.html#a9ebf8832444bfb71e5cc1549ec38e354">destroyThreadsPoolMsg</a></div><div class="ttdeci">void destroyThreadsPoolMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">销毁线程池</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00556">threads_pool.c:556</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_a9fd17f658f3015bed2089a4acd9dda5a"><div class="ttname"><a href="threads__pool_8c.html#a9fd17f658f3015bed2089a4acd9dda5a">insertSomeNewThreadMsgs</a></div><div class="ttdeci">static void insertSomeNewThreadMsgs(ThreadsPoolMsg_st_pt trdsPolMsgStPt, int newTrdMSgsCot)</div><div class="ttdoc">批量插入新线程信息</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00341">threads_pool.c:341</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_aad05cdcc30cc4fd66e4ff890ea5cb570"><div class="ttname"><a href="threads__pool_8c.html#aad05cdcc30cc4fd66e4ff890ea5cb570">destroyThreadMsgsLinkedList</a></div><div class="ttdeci">static void destroyThreadMsgsLinkedList(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">销毁线程信息链表</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00513">threads_pool.c:513</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_ab8f5739158324ca3499012ae04bce8cd"><div class="ttname"><a href="threads__pool_8c.html#ab8f5739158324ca3499012ae04bce8cd">inqueueNewTaskMsg</a></div><div class="ttdeci">static void inqueueNewTaskMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt, TaskMsg_st_pt newTaskMsgStPt)</div><div class="ttdoc">将新任务信息加入队列</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00079">threads_pool.c:79</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_ac81554b51840bdab1350772eb599c27b"><div class="ttname"><a href="threads__pool_8c.html#ac81554b51840bdab1350772eb599c27b">cleanUpHandle</a></div><div class="ttdeci">static void cleanUpHandle(void *arg)</div><div class="ttdoc">清理处理函数</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00025">threads_pool.c:25</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_af6ab15dabb1e0688a886e468d0f0b577"><div class="ttname"><a href="threads__pool_8c.html#af6ab15dabb1e0688a886e468d0f0b577">destroyTaskMsgsLinkedQueue</a></div><div class="ttdeci">static void destroyTaskMsgsLinkedQueue(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">销毁任务信息队列</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00535">threads_pool.c:535</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_af90c938ee855b735b0c0b9f82f9e6d67"><div class="ttname"><a href="threads__pool_8c.html#af90c938ee855b735b0c0b9f82f9e6d67">dequeueTaskMsg</a></div><div class="ttdeci">static TaskMsg_st_pt dequeueTaskMsg(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">从队列中取出任务信息</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00103">threads_pool.c:103</a></div></div>
<div class="ttc" id="athreads__pool_8c_html_afbfdf354a44f65186b3dfdd80e566b59"><div class="ttname"><a href="threads__pool_8c.html#afbfdf354a44f65186b3dfdd80e566b59">reduceThread</a></div><div class="ttdeci">int reduceThread(ThreadsPoolMsg_st_pt trdsPolMsgStPt)</div><div class="ttdoc">从线程池中移除线程</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8c_source.html#l00486">threads_pool.c:486</a></div></div>
<div class="ttc" id="athreads__pool_8h_html"><div class="ttname"><a href="threads__pool_8h.html">threads_pool.h</a></div><div class="ttdoc">线程池模块头文件</div></div>
<div class="ttc" id="athreads__pool_8h_html_a5a467b16d23990346745beeffa68a36f"><div class="ttname"><a href="threads__pool_8h.html#a5a467b16d23990346745beeffa68a36f">ThreadsPoolMsg_st_pt</a></div><div class="ttdeci">struct threadsPoolMsg * ThreadsPoolMsg_st_pt</div></div>
<div class="ttc" id="athreads__pool_8h_html_aad77b3322f3824da508dfbd0d04aa1a3"><div class="ttname"><a href="threads__pool_8h.html#aad77b3322f3824da508dfbd0d04aa1a3">UNLOCK_AND_CANCEL_CLEAN_UP</a></div><div class="ttdeci">#define UNLOCK_AND_CANCEL_CLEAN_UP(mtxUnPt)</div><div class="ttdoc">解锁并取消清理的宏</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00091">threads_pool.h:91</a></div></div>
<div class="ttc" id="athreads__pool_8h_html_ade228054bfa068c8720ccbdd9bd60f1f"><div class="ttname"><a href="threads__pool_8h.html#ade228054bfa068c8720ccbdd9bd60f1f">READY_CLEAN_UP_AND_LOCK</a></div><div class="ttdeci">#define READY_CLEAN_UP_AND_LOCK(cleanUpHandleFuncPt, mtxUnPt)</div><div class="ttdoc">准备清理并加锁的宏</div><div class="ttdef"><b>Definition</b> <a href="threads__pool_8h_source.html#l00080">threads_pool.h:80</a></div></div>
</div><!-- fragment --></div><!-- contents -->
<!-- start footer part -->
<hr class="footer"/><address class="footer"><small>
生成于 2025年 九月 13日 星期六 03:22:59 , 为 线程池使用 &#160;<a href="https://www.doxygen.org/index.html"><img class="footer" src="doxygen.svg" width="104" height="31" alt="doxygen"/></a> 1.9.8
</small></address>
</body>
</html>
